package com.example.x50;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UdpServer {
    /*
     *     实现UDP接收端
     *         实现封装数据包java.net.DatagramPacket 将数据接收
     *         实现输出传输    java.net.DatagramSocket 接受数据包
     *
     *     实现步骤：
     *         1.创建DatagramSocket对象，绑定端口号
     *               要和发送数据端口号一致
     *         2.创建字节数组，接受发来的数组
     *         3.创建数据包对象DatagramPacket
     *         4.调用DatagramSocket对象方法 receive(DatagramPacket dp)
     *               接受数据，数据放在数据包中
     *         5.拆包
     *                 发送的IP地址
     *                  数据包对象DatagramPacket()方法getAddress()获取的是发送端的IP地址对象
     *                 接受到的字节个数
     *                  数据包对象DatagramPacket()方法getLength()
     *                 发送方的端口号
     *              数据包对象DatagramPacket()方法getPort()
     *         6.关闭资源
     */

        public static byte[] rec(int port1) throws  IOException {
            //创建数据包传输对象DatagramSocket 绑定端口号
            DatagramSocket ds=new DatagramSocket(port1);
            //创建字节数组
            byte[] data=new byte[1024];
            //创建数据包对象，传递字节数组
            DatagramPacket dp=new DatagramPacket(data, data.length);
            //调用ds对象的方法receive传递数据包
            ds.receive(dp);


            //获取发送端的IP地址对象
//            String ip=dp.getAddress().getHostAddress();

            //获取发送的端口号
//            int port=dp.getPort();

            //获取接收到的字节数
//            int length=dp.getLength();
//            System.out.println(new String(data,0,length)+"...."+ip+":"+port);

            ds.close();
            return data;

        }
    }


